package com.xbongbong.pro.rabbitmq.binders;

import com.xbongbong.pro.rabbitmq.constant.CrmBinderConstant;
import com.xbongbong.pro.rabbitmq.constant.ScoreBinderConstant;
import com.xbongbong.pro.rabbitmq.constant.SmsBinderConstant;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Service;

/**
 * 评分 消息队列
 * @author chunyang.qin
 * @date 2020/12/7 18:48
 * @since v1.0
 * @version v1.0
 */
@Service("scoreConsumerBinder")
public interface ScoreConsumerBinder {

    /**
     * 评分 消息队列
     */
    @Input(ScoreBinderConstant.SCORE_INPUT)
    SubscribableChannel scoreInput();
}
